package com.spica.platform.kafka.consumer;


import com.spica.platform.kafka.core.NamedThreadFactory;

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

/**
 * kafka消费线程池-后续考虑使用spica-threadpool-starter提供的
 */
public class ThreadKit {
    public static final ExecutorService cachedThreadPool = Executors.newCachedThreadPool(new NamedThreadFactory("consumer", true));
}
